<?php
/**
 * Redis
 * @author zlj <389843954@qq.com>
 */
namespace app\common\model;
class Redis
{

    private $redis;

    /**
     * @param [string] $host [ip,默认为本地] 101.200.155.51
     * @param [int] $post [端口号] 
     */
    public function __construct($host = '101.200.155.51', $port = 6379) {
        $this->redis = new \Redis();
        //连接服务器
        $this->redis->connect($host, $port);
        //连接远程时授权
        $this->redis->auth("swaylink_123");

        return $this->redis;
    }

    /**
     * 设置值  构建一个字符串
     * @param [string] $key [KEY名称]
     * @param [string] $value  [设置值]
     * @param [int] $timeOut [时间  0表示无过期时间]
     */
    public function set($key, $value, $timeOut=0) {
        $retRes = $this->redis->set($key, $value);
        if ($timeOut > 0){
            $this->redis->expire($key, $timeOut);
        }
        return $retRes;
    }

    /**
     * 构建一个集合(无序集合)
     * @param [string] $key [集合Y名称]
     * @param [string|array] $value  [值]
     * @param [int] $timeOut [时间  0表示无过期时间]
     */
    public function sadd($key,$value,$timeOut=0){
        
        $return = $this->redis->sadd($key,$value);
        if ($timeOut > 0){
            $this->redis->expire($key, $timeOut);
        }
        return $return;
    }
    
    /**
     * 构建一个集合(有序集合)
     * @param [string] $key [集合名称]
     * @param [string|array] $value  [值]
     * @param [string] $score [排序,用于排序] 
     * @param [int] $timeOut [时间  0表示无过期时间] 
     */
    public function zadd($key,$score,$value,$timeOut=0){
        $return = $this->redis->zadd($key,$score,$value);
        
        if ($timeOut > 0){
            $this->redis->expire($key, $timeOut);
        }

        return $return;
    }
    
    /**
     * 取集合对应元素
     * @param [string] $setName [集合名字]
     */
    public function smembers($setName){
        return $this->redis->smembers($setName);
    }

    /**
     * 构建一个列表(先进后去，类似栈)
     * @param [sting] $key [KEY名称]
     * @param [sting] $value [值]
     * @param [int] $timeOut [时间  0表示无过期时间]
     */
    public function lpush($key,$value,$timeOut=0){
        $return = $this->redis->LPUSH($key,$value);

        if ($timeOut > 0){
            $this->redis->expire($key, $timeOut);
        }

        return $return;
    }
    
    /**
     * 构建一个列表(先进先去，类似队列)
     * @param [sting] $key [KEY名称]
     * @param [string] $value [值]
     * @param [int] $timeOut [时间  0表示无过期时间]
     */
    public function rpush($key,$value,$timeOut=0){
        $return = $this->redis->rpush($key,$value);
        
        if ($timeOut > 0){
            $this->redis->expire($key, $timeOut);
        }
        return $return;
    }
    /**
     * 获取所有列表数据（从头到尾取）
     * @param [sting] $key [KEY名称]
     * @param [int] $head  [开始]
     * @param [int] $tail     [结束]
     */
    public function lranges($key,$head=0,$tail=-1){
        return $this->redis->lrange($key,$head,$tail);
    }
    
    /**
     * HASH类型
     * @param [string] $tableName  [表名字key]
     * @param [string] $key     [字段名字]
     * @param [sting] $value    [值]
     * @param [int] $timeOut [时间  0表示无过期时间]
     */
    public function hset($tableName,$field,$value, $timeOut=0){
        
        $return = $this->redis->hset($tableName,$field,$value);

        if ($timeOut > 0){
            $this->redis->expire($tableName, $timeOut);
        }
        return $return;
    }
    
    /**
     * 判断字段是否存在(查找此字段值)
     * @param  [string] $tableName [表名]
     * @param  [string] $field     [字段名]
     */
    public function hget($tableName,$field){
        $return = $this->redis->hget($tableName,$field);

        return $return;
    }
    
    public function hGetAll($tableName){
        return $this->redis->hGetAll($tableName);
    }
    
    public function hSetAll($tableName, $array){
        return $this->redis->hMset($tableName, $array);
    }
    /**
     *删除hash表中的域
     *@param [string] $tableName [域名]
     *@param [string] $field     [字段名]
     * */
    public function hDel($tableName, $field ){
        return $this->redis->hDel($tableName, $field);        
    }
    
    
    /**
     * 设置多个值
     * @param [array] $keyArray [KEY名称]
     * @param [string|array] $value [获取得到的数据]
     * @param [int] $timeOut [时间]
     */
    public function sets($keyArray, $timeout=0) {
        if (is_array($keyArray)) {
            $retRes = $this->redis->mset($keyArray);
            if ($timeout > 0) {
                foreach ($keyArray as $key => $value) {
                    $this->redis->expire($key, $timeout);
                }
            }
            return $retRes;
        } else {
            return "Call  " . __FUNCTION__ . " method  parameter  Error !";
        }
    }

    /**
     * 通过key获取数据
     * @param [string] $key [KEY名称]
     */
    public function get($key) {
        $result = $this->redis->get($key);
        return $result;
    }

    /**
     * 同时获取多个值
     * @param [array] $keyArray [获key数值]
     */
    public function gets($keyArray) {
        if (is_array($keyArray)) {
            return $this->redis->mget($keyArray);
        } else {
            return "Call  " . __FUNCTION__ . " method  parameter  Error !";
        }
    }

    /**
     * 获取所有key名，不是值
     */
    public function keyAll() {
        return $this->redis->keys('*');
    }

    /**
     * 模糊查询key名
     * @param  [string] $word [域名关键字]
     */
    public function keys($word){
         return $this->redis->keys("*".$word."*");
    }
    
    /**
     * 自定义模糊查询key值
     * @param  [string] $word [域名关键字]
     * */
    public function keysNative($word){
        return $this->redis->keys($word);
    }
    /**
     * 返回名称为key的zset（元素已按score从小到大排序）中的index从start到end的所有元素
     * @param [string] $key [域名]
     * @param [string] $start [开始:0表示第一个  默认为   0]
     * @param [string] $end  [结束:-1最后一个 默认为  -1]
     */
    public function zRange($key, $start=0, $end=-1,$type=false){
        
        if($type){
           $res = $this->redis->zRange($key,$start,$end,"withscores");
        }else{
           $res = $this->redis->zRange($key,$start,$end);
        }
        return $res;
    }

    /**
     * 删除有序集合保存在key开始和结束的排序所有元素
     * @param  [string]  $key   [域名]
     * @param  [integer] $start [开始值]
     * @param  [integer] $end   [结束值]
     * @return [int]         [删除的元素数量]
     */
    public function zremRangeByRank($key, $start=0, $end=-1){

        return $this->redis->ZREMRANGEBYRANK($key, $start, $end);
    }
    
    /**
     * 查询有序集合
     * @param  [string]  $key   [设备号]
     * @param  [string]  $start [具体分数 / -inf:<=$end]
     * @param  [string]  $end   [具体分数 / +inf:$start<=]
     * @param  [bool] $type  [true:带时间  false:不带]
     */
    public function zRangeByScore($key, $start, $end,$type=false){
        
        if($type){
           $res = $this->redis->zRangeByScore($key,$start,$end,array("withscores"=>true));
        }else{
           $res = $this->redis->zRangeByScore($key,$start,$end);
        }
        return $res;
    }
    
    /**
     * 删除有序集合指定值
     * @param  [string] $key [域名]
     * @param  [string] $val [value值]
     */
    public function zrem($key,$val){
        return $this->redis->zrem($key,$val);
    }

    /**
     * 随机出redis 中的域
     */
    public function randomkey(){
        return $this->redis->RANDOMKEY();
    }

    /**
     * 切换数据库
     * @param  [string] $db  [切换数据库 默认:0号数据库]
     */
    public function select($db=0){
        return $this->redis->select($db);
    }
     
    /**
     * 删除一条数据key
     * @param [string] $key [删除KEY的名称]
     */
    public function del($key) {
        return $this->redis->delete($key);
    }

    /**
     * 同时删除多个key数据
     * @param [array] $keyArray [KEY集合]
     */
    public function dels($keyArray) {
        if (is_array($keyArray)) {
            return $this->redis->del($keyArray);
        } else {
            return "Call  " . __FUNCTION__ . " method  parameter  Error !";
        }
    }
    
    /**
     * 数据自增
     * @param [string] $key [KEY名称]
     */
    public function increment($key) {
        return $this->redis->incr($key);
    }
    
    /**
     * 数据自减
     * @param [string] $key [KEY名称]
     */
    public function decrement($key) {
        return $this->redis->decr($key);
    }
   
    
    /**
     * 判断key是否存在
     * @param [string] $key [KEY名称]
     */
    public function isExists($key){
        return $this->redis->exists($key);
    }

    /**
     * 重命名- 当且仅当newkey不存在时，将key改为newkey ，当newkey存在时候会报错哦RENAME和 rename不一样，它是直接更新（存在的值也会直接更新）
     * @param [string] $Key [KEY名称]
     * @param [string] $newKey [新key名称]
     */
    public function updateName($key,$newKey){
        return $this->redis->RENAMENX($key,$newKey);
    }
    
    /**
    * 获取KEY存储的值类型
    * none(key不存在) int(0)  string(字符串) int(1)   list(列表) int(3)  set(集合) int(2)   zset(有序集) int(4)    hash(哈希表) int(5)
    * @param string $key KEY名称
    */
    public function dataType($key){
        return $this->redis->type($key);
    }
   
    /**
     * 清空数据,清空所有redis数据
     */
    public function flushAll() {
        return $this->redis->flushAll();
    }

    /**
     * 清空当前数据库数据
     */
    public function flushdb() {
        return $this->redis->flushdb();
    }

    /**
     * 保存数据
     * @param [string] $tablename [域名]
     * @param [array] $dataArr   [数组形式]
     * @param [int] $timeOut [过期时间设置]
     */
    public function hMset($tablename, $dataArr,$timeOut=0) {

        $return = $this->redis->hMset($tablename, $dataArr);

        if ($timeOut > 0){
            $this->redis->expire($tablename, $timeOut);
        }
        return $return;
    }
    
    /**
     * 判断设备在redis几号数据库
     * @param string $dev_id 设备号
     * @return mixed
     * 
     * */
    public function whereRedis($dev_id) {
        $this->select(0);
        $r0 = $this->isExists($dev_id);
        if($r0){
            //在0号数据库
            return 0;
        }
        
        $this->select(2);
        $r2 = $this->isExists($dev_id);
        if($r2){
            //在2号数据库
            return 2;
        }else{
            //不在redis中,代表设备掉线
            return false;
        }
    }

    /**
     * 获取设备的通知地址
     * @param string $dev_id 设备号
     * @return mixed
     * */
    public function getRedisAddr($dev_id){
        $select = $this->whereRedis($dev_id);
        if(false === $select) return false;
        
        $this->redis->select($select);
        $temp = json_decode($this->redis->hGet($dev_id, 'inform_addr'), true);

        if($temp){
            foreach ($temp as &$v){
                $v = json_decode($v, true);
            }
            unset($v);
            return $temp;
        }else{
            return false;
        }
    }
}